package com.bjbn.service;

import com.bjbn.entity.FimsDataOri;

/**
 * FIMS数据服务接口
 * 
 * @author bjbn
 */
public interface FimsDataService {

    /**
     * 保存FIMS原始数据
     * 
     * @param fimsDataOri FIMS原始数据
     * @return 是否保存成功
     */
    boolean saveFimsData(FimsDataOri fimsDataOri);

    /**
     * 保存到Elasticsearch
     * 
     * @param fimsDataOri FIMS原始数据
     * @return 是否保存成功
     */
    boolean saveToElasticsearch(FimsDataOri fimsDataOri);

    /**
     * 推送到Kafka
     * 
     * @param fimsDataOri FIMS原始数据
     * @return 是否推送成功
     */
    boolean sendToKafka(FimsDataOri fimsDataOri);

    /**
     * 清理过期数据
     * 
     * @return 清理的记录数
     */
    int cleanExpiredData();
} 